home *** CD-ROM | disk | FTP | other *** search
/ Internet Info 1994 March / Internet Info CD-ROM (Walnut Creek) (March 1994).iso / networking / terms / kermit / b / ckcpro.w < prev    next >
Encoding:
Text File  |  1993-07-09  |  28.0 KB  |  879 lines
  1. char *protv = "C-Kermit Protocol Module 5A(055), 4 Jun 93"; /* -*-C-*- */
  2.  
  3. /* C K C P R O  -- C-Kermit Protocol Module, in Wart preprocessor notation. */
  4. /*
  5.   Author: Frank da Cruz (fdc@columbia.edu, FDCCU@CUVMA.BITNET),
  6.   Columbia University Academic Information Systems, New York City.
  7.  
  8.   Copyright (C) 1985, 1993, Trustees of Columbia University in the City of New
  9.   York.  The C-Kermit software may not be, in whole or in part, licensed or
  10.   sold for profit as a software product itself, nor may it be included in or
  11.   distributed with commercial products or otherwise distributed by commercial
  12.   concerns to their clients or customers without written permission of the
  13.   Office of Kermit Development and Distribution, Columbia University.  This
  14.   copyright notice must not be removed, altered, or obscured.
  15. */
  16. #include "ckcdeb.h"
  17. #include "ckcasc.h"
  18. #include "ckcker.h"
  19. /*
  20.  Note -- This file may also be preprocessed by the Unix Lex program, but 
  21.  you must indent the above #include statements before using Lex, and then
  22.  restore them to the left margin in the resulting C program before compilation.
  23.  Also, the invocation of the "wart()" function below must be replaced by an
  24.  invocation  of the "yylex()" function.  It might also be necessary to remove
  25.  comments in the %%...%% section.
  26. */
  27.  
  28. /* State definitions for Wart (or Lex) */
  29. %states ipkt rfile rattr rdata ssinit ssfile ssattr ssdata sseof sseot
  30. %states serve generic get rgen
  31.  
  32. /* External C-Kermit variable declarations */
  33.   extern char *versio, *srvtxt, *cmarg, *cmarg2, **cmlist;
  34.   extern char filnam[], ttname[];
  35.   extern CHAR sstate, *rpar(), encbuf[], *srvptr, *data;
  36.   extern int timint, rtimo, nfils, hcflg, xflg, flow, mdmtyp, network;
  37. #ifdef NETCONN
  38. #ifdef CK_SPEED
  39.   extern int ttnproto;            /* Network protocol */
  40.   extern short ctlp[];            /* Control-character prefix table */
  41. #endif /* CK_SPEED */
  42. #endif /* NETCONN */
  43.   extern int cxseen, czseen, server, srvdis, local, displa, bctu, bctr, bctl;
  44.   extern int quiet, tsecs, parity, backgrd, nakstate, atcapu, wslotn, winlo;
  45.   extern int wslots, success, xitsta, rprintf, discard, cdtimo, keep, fdispla;
  46.   extern int timef, stdinf;
  47.   extern long speed, ffc;
  48.   extern char *DIRCMD, *DIRCM2, *DELCMD, *TYPCMD, *SPACMD, *SPACM2, *WHOCMD;
  49.   extern CHAR *rdatap;
  50.   extern struct zattr iattr;
  51. #ifdef DYNAMIC
  52.   extern CHAR *srvcmd;
  53. #else
  54.   extern CHAR srvcmd[];
  55. #endif /* DYNAMIC */
  56.  
  57. #ifndef NOSPL
  58.   extern int cmdlvl;
  59. #else
  60.   extern int tlevel;
  61. #endif /* NOSPL */
  62.  
  63. #ifdef NOMSEND
  64.   extern int sndsrc;
  65. #endif /* NOMSEND */
  66.  
  67. /* Flags for the ENABLE and DISABLE commands */
  68. extern int
  69.   en_cwd, en_del, en_dir, en_fin, en_get, en_bye,
  70.   en_hos, en_sen, en_spa, en_set, en_typ, en_who;
  71.  
  72. /* Global variables declared here */
  73.  
  74.   int what = W_NOTHING;            /* What we're doing */
  75.  
  76. /* Local variables */
  77.  
  78.   static char vstate = 0;          /* Saved State   */
  79.   static char vcmd = 0;            /* Saved Command */
  80.  
  81.   static int x;                /* General-purpose integer */
  82.   static char *s;            /* General-purpose string pointer */
  83.  
  84. /* Macros - Note, BEGIN is predefined by Wart (and Lex) as "state = ", */
  85. /* BEGIN is NOT a GOTO! */
  86. #define TINIT  if (tinit() < 0) return(-9)
  87. #define SERVE  TINIT; nakstate = 1; what = W_NOTHING; cmarg2 = ""; BEGIN serve
  88. #define RESUME if (server) { SERVE; } else { sleep(2); return(0); }
  89. #define QUIT x=quiet; quiet=1; clsif(); clsof(1); tsecs=gtimer(); quiet=x; \
  90.  return(1)
  91.  
  92. %%
  93. /*
  94.   Protocol entry points, one for each start state (sstate).
  95.   The lowercase letters are internal "inputs" from the user interface.
  96. */
  97.  
  98. s { TINIT;                /* Do Send command */
  99.     if (sinit()) BEGIN ssinit;
  100.        else RESUME; }
  101.  
  102. v { TINIT; nakstate = 1; BEGIN get; }                    /* Receive */
  103. r { TINIT; vstate = get;  vcmd = 0;   sipkt('I'); BEGIN ipkt; } /* Get */
  104. c { TINIT; vstate = rgen; vcmd = 'C'; sipkt('I'); BEGIN ipkt; } /* Host */
  105. k { TINIT; vstate = rgen; vcmd = 'K'; sipkt('I'); BEGIN ipkt; } /* Kermit */
  106. g { TINIT; vstate = rgen; vcmd = 'G'; sipkt('I'); BEGIN ipkt; } /* Generic */
  107.  
  108. x { sleep(1); SERVE; }            /* Be a Server */
  109.  
  110. a { if (!data) TINIT;            /* "ABEND" -- Tell other side. */
  111.     errpkt((CHAR *)"User cancelled");
  112.     success = 0;
  113.     return(0); }            /* Return from protocol. */
  114.  
  115. /*
  116.   Dynamic states: <current-states>input-character { action }
  117.   nakstate != 0 means we're in a receiving state, in which we send ACKs & NAKs.
  118. */
  119. <rgen,get,serve>S {            /* Receive Send-Init packet. */
  120.     if (state == serve && !en_sen) {    /* Not allowed if in server mode */
  121.     errpkt((CHAR *)"SEND disabled"); /* and SEND is disabled. */
  122.     SERVE;
  123.     } else {                /* OK to go ahead. */
  124.     nakstate = 1;            /* Can send NAKs from here. */
  125.     rinit(rdatap);            /* Set parameters */
  126.     bctu = bctr;            /* Switch to agreed-upon block check */
  127.     bctl = (bctu == 4) ? 2 : bctu;    /* Set block-check length */
  128.     what = W_RECV;            /* Remember we're receiving */
  129.     resetc();            /* Reset counters */
  130.     rtimer();            /* Reset timer */
  131.     BEGIN rfile;            /* Go into receive-file state */
  132.     }
  133. }
  134.  
  135. /* States in which we get replies back from commands sent to a server. */
  136. /* Complicated because direction of protocol changes, packet number    */
  137. /* stays at zero through I-G-S sequence, and complicated even more by  */
  138. /* sliding windows buffer allocation. */
  139.  
  140. <ipkt>Y {                /* Get ack for I-packet */
  141.     spar(rdatap);            /* Set parameters */
  142. #ifdef COMMENT
  143.     getsbuf(winlo = 0);            /* Set window-low back to zero */
  144. #else
  145.     winlo = 0;
  146. #endif /* COMMENT */
  147.     if (vcmd) {                /* If sending a generic command */
  148.     scmd(vcmd,(CHAR *)cmarg);    /* Do that */
  149.     vcmd = 0;            /* and then un-remember it. */
  150.     } else if (vstate == get) srinit();    /* If sending GET command, do that. */
  151.     rtimer();                /* Reset the elapsed seconds timer. */
  152.     winlo = 0;                /* Window back to 0, again. */
  153.     nakstate = 1;            /* Can send NAKs from here. */
  154.     BEGIN vstate;            /* Switch to desired state */
  155. }
  156.  
  157. <ipkt>E {                /* Ignore Error reply to I packet */
  158. #ifdef COMMENT
  159.     getsbuf(winlo = 0);            /* Set window-low back to zero */
  160. #else
  161.     winlo = 0;
  162. #endif /* COMMENT */
  163.     if (vcmd) {                /* In case other Kermit doesn't */
  164.     scmd(vcmd,(CHAR *)cmarg);    /* understand I-packets. */
  165.     vcmd = 0;            /* Otherwise act as above... */
  166.     } else if (vstate == get) srinit();
  167.     winlo = 0;                /* Back to packet 0 again. */
  168.     freerpkt(winlo);            /* Discard the Error packet. */
  169.     nakstate = 1;            /* Can send NAKs from here. */
  170.     BEGIN vstate;
  171. }
  172.  
  173. <get>Y {        /* Resend of previous I-pkt ACK, same seq number! */
  174.     srinit();
  175. }
  176.  
  177. /* States in which we're being a server */
  178.  
  179. <serve>I {                /* Get I-packet */
  180.     spar(rdatap);            /* Set parameters from it */
  181.     ack1(rpar());            /* Respond with our own parameters */
  182.     pktinit();                /* Reinitialize packet numbers */
  183. }
  184.  
  185. <serve>R {                /* Get Receive-Init (GET) */
  186.     debug(F100,"<serve>R","",0);
  187.     if (!en_get) {            /* Only if not disabled!  */
  188.     errpkt((CHAR *)"GET disabled");
  189.     SERVE;
  190.     } else {                /* OK to go ahead. */
  191.     srvptr = srvcmd;        /* Point to server command buffer */
  192.     decode(rdatap,putsrv,0);    /* Decode the GET command into it */
  193.     /* Accept multiple filespecs */
  194.         cmarg2 = "";            /* Don't use cmarg2 */
  195.     cmarg = "";            /* Don't use cmarg */
  196. #ifndef NOMSEND                /* New way. */
  197.     nfils = fnparse((char *)srvcmd); /* Use cmlist instead */
  198. #else
  199.     nfils = 0 - zxpand((char *)srvcmd);
  200. #endif /* NOMSEND */
  201.     nakstate = 0;            /* Now I'm the sender! */
  202.     if (sinit()) {            /* Send Send-Init */
  203.         timint = chktimo(rtimo,timef); /* Switch to per-packet timer */
  204.         BEGIN ssinit;        /* If successful, switch state */
  205.     } else { SERVE; }        /* Else back to server command wait */
  206.     }
  207. }
  208.  
  209. <serve>G {                /* Generic server command */
  210.     srvptr = srvcmd;            /* Point to command buffer */
  211.     decode(rdatap,putsrv,0);        /* Decode packet data into it */
  212.     putsrv('\0');            /* Insert a couple nulls */
  213.     putsrv('\0');            /* for termination */
  214.     if (srvcmd[0]) {
  215.     sstate = srvcmd[0];        /* Set requested start state */
  216.     nakstate = 0;            /* Now I'm the sender. */
  217.     what = W_REMO;            /* Doing a REMOTE command. */
  218.     if (timint < 1)
  219.       timint = chktimo(rtimo,timef); /* Switch to per-packet timer */
  220.     BEGIN generic;            /* Switch to generic command state */
  221.     } else {
  222.     errpkt((CHAR *)"Badly formed server command"); /* report error */
  223.     SERVE;                /* & go back to server command wait */
  224.     }
  225. }
  226.  
  227. <serve>C {                /* Receive Host command */
  228.     if (!en_hos) {
  229.     errpkt((CHAR *)"REMOTE HOST disabled");
  230.     SERVE;
  231.     } else {
  232.     srvptr = srvcmd;        /* Point to command buffer */
  233.     decode(rdatap,putsrv,0);    /* Decode command packet into it */
  234.     putsrv('\0');            /* Null-terminate */
  235.     nakstate = 0;            /* Now sending, not receiving */
  236.     if (syscmd((char *)srvcmd,"")) { /* Try to execute the command */
  237.         what = W_REMO;        /* Doing a REMOTE command. */
  238.         if (timint < 1)
  239.           timint = chktimo(rtimo,timef); /* Switch to per-packet timer */
  240.         BEGIN ssinit;        /* If OK, send back its output */
  241.     } else {            /* Otherwise */
  242.         errpkt((CHAR *)"Can't do system command"); /* report error */
  243.         SERVE;            /* & go back to server command wait */
  244.     }
  245.     }
  246. }
  247.  
  248. <serve>q {                /* User typed Ctrl-C... */
  249.     if (!en_fin) {
  250.     errpkt((CHAR *)"QUIT disabled");
  251.     SERVE;
  252.     } else {
  253.     success = 0; QUIT;
  254.     }
  255. }
  256.  
  257. <serve>N {                /* Server got a NAK in command-wait */
  258.     errpkt((CHAR *)"Did you say RECEIVE instead of GET?");
  259.     SERVE;
  260. }
  261.  
  262. <serve>. {                /* Any other command in this state */
  263.     errpkt((CHAR *)"Unimplemented server function"); /* we don't know about */
  264.     SERVE;                /* back to server command wait */
  265. }
  266.  
  267. <generic>C {                /* Got REMOTE CWD command */
  268.     if (!en_cwd) {
  269.     errpkt((CHAR *)"REMOTE CD disabled");
  270.     SERVE;
  271.     } else {
  272.     if (!cwd((char *)(srvcmd+1))) errpkt((CHAR *)"Can't change directory");
  273.     SERVE;                /* Back to server command wait */
  274.     }
  275. }
  276.  
  277. <generic>D {                /* REMOTE DIRECTORY command */
  278.     char *n2;
  279.     if (!en_dir) {            /* If DIR is disabled, */
  280.     errpkt((CHAR *)"REMOTE DIRECTORY disabled"); /* refuse. */
  281.     SERVE;
  282.     } else {                /* DIR is enabled. */
  283.     if (!en_cwd) {            /* But if CWD is disabled */
  284.         zstrip((char *)(srvcmd+2),&n2); /* and they included a pathname, */
  285.         if (strcmp((char *)(srvcmd+2),n2)) { /* refuse. */
  286.         errpkt((CHAR *)"Access denied");
  287.         SERVE;            /* Remember, this is not a goto! */
  288.         }
  289.     }    
  290.     if (state == generic) {            /* It's OK to go ahead. */
  291.         n2 = (*(srvcmd+2)) ? DIRCMD : DIRCM2;
  292.         if (syscmd(n2,(char *)(srvcmd+2)))  /* If it can be done */
  293.           BEGIN ssinit;            /* send the results back */
  294.         else {                /* otherwise */
  295.         errpkt((CHAR *)"Can't list directory"); /* report failure, */
  296.         SERVE;            /* return to server command wait */
  297.         }
  298.     }
  299.     }
  300. }
  301.  
  302. <generic>E {                /* REMOTE DELETE (Erase) command */
  303.     char *n2;
  304.     if (!en_del) {
  305.     errpkt((CHAR *)"REMOTE DELETE disabled");    
  306.     SERVE;
  307.     } else {
  308.     if (!en_cwd) {            /* But if CWD is disabled */
  309.         zstrip((char *)(srvcmd+2),&n2); /* and they included a pathname, */
  310.         if (strcmp((char *)(srvcmd+2),n2)) { /* refuse. */
  311.         errpkt((CHAR *)"Access denied");
  312.         SERVE;            /* Remember, this is not a goto! */
  313.         }
  314.     }    
  315.     if (state == generic) {            /* It's OK to go ahead. */
  316.         if (syscmd(DELCMD,(char *)(srvcmd+2))) /* Try to do it */
  317.           BEGIN ssinit;            /* If OK send results back */
  318.         else {                /* otherwise */
  319.         errpkt((CHAR *)"Can't remove file"); /* report failure */
  320.         SERVE;            /* & return to server command wait */
  321.         }
  322.     }
  323.     }
  324. }
  325.  
  326. <generic>F {                /* FINISH */
  327.     if (!en_fin) {
  328.     errpkt((CHAR *)"FINISH disabled");    
  329.     SERVE;
  330.     } else {
  331.     ack();                /* Acknowledge */
  332.     screen(SCR_TC,0,0l,"");        /* Display */
  333.     return(0);            /* Done */
  334.     }
  335. }
  336.  
  337. <generic>L {                /* BYE (LOGOUT) */
  338.     if (!en_bye) {
  339.     errpkt((CHAR *)"BYE disabled");    
  340.     SERVE;
  341.     } else {
  342.     ack();                /* Acknowledge */
  343.     ttres();            /* Reset the terminal */
  344.     screen(SCR_TC,0,0l,"");        /* Display */
  345.     doclean();            /* Clean up files, etc */
  346.     return(zkself());        /* Try to log self out */
  347.     }
  348. }
  349.  
  350. <generic>H {                /* REMOTE HELP */
  351.     if (sndhlp()) BEGIN ssinit;        /* Try to send it */
  352.     else {                /* If not ok, */
  353.     errpkt((CHAR *)"Can't send help"); /* send error message instead */
  354.     SERVE;                /* and return to server command wait */
  355.     }
  356. }
  357.  
  358. <generic>S {                /* REMOTE SET */
  359.     if (!en_set) {
  360.     errpkt((CHAR *)"REMOTE SET disabled");
  361.     SERVE;
  362.     } else {
  363.     if (remset((char *)(srvcmd+1)))    /* Try to do what they ask */
  364.       ack();            /* If OK, then acknowledge */
  365.     else                /* Otherwise */
  366.       errpkt((CHAR *)"Unknown REMOTE SET parameter"); /* give error msg */
  367.     SERVE;                /* Return to server command wait */
  368.     }
  369. }
  370.  
  371. <generic>T {                /* REMOTE TYPE */
  372.     char *n2;
  373.     if (!en_typ) {
  374.     errpkt((CHAR *)"REMOTE TYPE disabled");
  375.     SERVE;
  376.     } else {
  377.     if (!en_cwd) {            /* But if CWD is disabled */
  378.         zstrip((char *)(srvcmd+2),&n2); /* and they included a pathname, */
  379.         if (strcmp((char *)(srvcmd+2),n2)) { /* refuse. */
  380.         errpkt((CHAR *)"Access denied");
  381.         SERVE;            /* Remember, this is not a goto! */
  382.         }
  383.     }    
  384.     if (state == generic) {            /* It's OK to go ahead. */
  385.         if (syscmd(TYPCMD,(char *)(srvcmd+2))) /* Try */
  386.           BEGIN ssinit;            /* OK */
  387.         else {                /* not OK */
  388.         errpkt((CHAR *)"Can't type file"); /* give error message */
  389.         SERVE;            /* wait for next server command */
  390.         }
  391.     }
  392.     }
  393. }
  394.  
  395. <generic>U {                /* REMOTE SPACE */
  396.     if (!en_spa) {
  397.     errpkt((CHAR *)"REMOTE SPACE disabled");
  398.     SERVE;
  399.     } else {
  400.     x = *(srvcmd+1);        /* Get area to check */
  401.     x = ((x == '\0') || (x == SP)
  402. #ifdef OS2
  403.          || (x == '!')
  404. #endif /* OS2 */
  405.          );
  406.     if (!x && !en_cwd) {        /* If CWD disabled and they gave */
  407.         errpkt((CHAR *)"Access denied"); /* a non-default area, */
  408.         SERVE;            /* refuse. */
  409.     } else {
  410. #ifdef OS2
  411. _PROTOTYP(int sndspace,(int));
  412.         if (sndspace(x ? toupper(srvcmd[2]) : 0))
  413.           BEGIN ssinit;        /* Try to send it */
  414.         else {            /* If not ok, */
  415.         errpkt((CHAR *)"Can't send space"); /* send error message */
  416.         SERVE;            /* and return to server command wait */
  417.         }
  418. #else
  419.         x = (x ? syscmd(SPACMD,"") : syscmd(SPACM2,(char *)(srvcmd+2)));
  420.         if (x) {                /* If we got the info */
  421.         BEGIN ssinit;            /* send it */
  422.         } else {                /* otherwise */
  423.         errpkt((CHAR *)"Can't check space"); /* send error message */
  424.         SERVE;            /* and await next server command */
  425.         }
  426. #endif /* OS2 */
  427.     }
  428.     }
  429. }
  430.  
  431. <generic>W {                /* REMOTE WHO */
  432.     if (!en_who) {
  433.     errpkt((CHAR *)"REMOTE WHO disabled");
  434.     SERVE;
  435.     } else {
  436.     if (syscmd(WHOCMD,(char *)(srvcmd+2))) /* The now-familiar scenario. */
  437.       BEGIN ssinit;
  438.     else {
  439.         errpkt((CHAR *)"Can't do who command");
  440.         SERVE;
  441.     }
  442.     }
  443. }
  444.  
  445. <generic>q {
  446.     if (!en_fin) {            /* Ctrl-C typed */
  447.     errpkt((CHAR *)"QUIT disabled");
  448.     SERVE;
  449.     } else {
  450.     success = 0; QUIT;
  451.     }
  452. }
  453.  
  454. <generic>. {                /* Anything else in this state... */
  455.     errpkt((CHAR *)"Unimplemented REMOTE command"); /* Complain */
  456.     SERVE;                /* and return to server command wait */
  457. }
  458.  
  459. <rgen>Y {                /* Short-Form reply */
  460.     decode(rdatap,puttrm,0);        /* in ACK Data field */
  461.     if (rdatap && *rdatap) conoll("");    /* Maybe add a CRLF */
  462.     RESUME;
  463. }
  464.  
  465. <rgen,rfile>F {                /* File header */
  466.     xflg = 0;                /* Not screen data */
  467.     if (!rcvfil(filnam)) {        /* Figure out local filename */
  468.     errpkt((CHAR *)"Can't transform filename"); /* Trouble */
  469.     RESUME;
  470.     } else {                /* OK to receive */
  471.     encstr((CHAR *)filnam);        /* Encode the name */
  472.     ack1((CHAR *)(encbuf+7));    /* Send it back in ACK */
  473.     initattr(&iattr);        /* Clear file attribute structure */
  474.     if (window(wslotn) < 0) {    /* Allocate negotiated window slots */
  475.         errpkt((CHAR *)"Can't open window");
  476.         RESUME;
  477.     }
  478.     BEGIN rattr;            /* Now expect Attribute packets */
  479.     }
  480. }
  481.  
  482. <rgen,rfile>X {                /* X-packet instead of file header */
  483.     xflg = 1;                /* Screen data */
  484.     ack();                /* Acknowledge the X-packet */
  485.     initattr(&iattr);            /* Initialize attribute structure */
  486.     if (window(wslotn) < 0) {        /* allocate negotiated window slots */
  487.     errpkt((CHAR *)"Can't open window");
  488.     RESUME;
  489.     }
  490.     what = W_REMO;            /* we're doing a REMOTE command */
  491.     BEGIN rattr;            /* Expect Attribute packets */
  492. }
  493.  
  494. <rattr>A {                /* Attribute packet */
  495.     if (discard) {            /* If SET FILE COLLISION DISCARD */
  496.     ack1((CHAR *)"N");        /* refuse it */
  497.     screen(SCR_ST,ST_REFU,0L,"file collision setting");
  498.     } else if (gattr(rdatap,&iattr) == 0) { /* Read into attribute structure */
  499.     ack();                /* If OK, acknowledge */
  500.     } else {                /* Otherwise */
  501.     ack1((CHAR *)iattr.reply.val);    /* refuse to accept the file */
  502.     screen(SCR_ST,ST_REFU,0L,getreason(iattr.reply.val)); /* give reason */
  503.     }
  504. }
  505.  
  506. <rattr>D {                /* First data packet */
  507.     if (discard) {            /* if we're discarding the file */
  508.     ack1((CHAR *)"X");        /* just ack the data like this. */
  509.     BEGIN rdata;            /* and wait for more data packets. */
  510.     } else {                /* Not discarding. */
  511.     if (xflg)            /* If screen data */
  512.       x = opent(&iattr);        /* "open" the screen */
  513.     else                /* otherwise */
  514.       x = opena(filnam,&iattr);    /* open the file, with attributes */
  515.     if (x) {            /* If file was opened ok */
  516.         if (decode(rdatap,putfil,1) < 0) { /* decode first data packet */
  517.         errpkt((CHAR *)"Error writing data");
  518.         RESUME;
  519.         }
  520.         ack();            /* acknowledge it */
  521.         BEGIN rdata;        /* and switch to receive-data state */
  522.     } else {            /* otherwise */
  523.         errpkt((CHAR *)"Can't open file");    /* send error message */
  524.         RESUME;            /* and quit. */
  525.     }
  526.     }
  527. }
  528.  
  529. <rfile>B {                /* EOT, no more files */
  530.     ack();                /* Acknowledge */
  531.     tsecs = gtimer();            /* Get timing for statistics */
  532.     reot();                /* Do EOT things */
  533.     RESUME;                /* and quit */
  534. }
  535.  
  536. <rdata>D {                /* Data packet */
  537.     if (cxseen || discard)        /* If file interrupt */
  538.       ack1((CHAR *)"X");        /* put "X" in ACK */
  539.     else if (czseen)            /* If file-group interrupt */
  540.       ack1((CHAR *)"Z");        /* put "Z" in ACK */
  541.     else if (decode(rdatap,putfil,1) < 0) { /* Normal case, decode to file */
  542.     errpkt((CHAR *)"Error writing data"); /* If failure, */
  543.     clsof(!keep);            /*   Close & keep/discard the file */
  544.     RESUME;                /* Send ACK only after data */
  545.     } else ack();            /* written to file OK. */
  546. }
  547.  
  548. <rattr>Z {                /* EOF immediately after A-Packet. */
  549.     if (xflg)                /* Zero-length file. If screen data */
  550.       x = opent(&iattr);        /* "open" the screen */
  551.     else                /* otherwise */
  552.       x = opena(filnam,&iattr);        /* open the file, with attributes. */
  553.     if (!x || reof(filnam, &iattr) < 0) { /* Now close & dispose of the file */
  554.     errpkt((CHAR *)"Can't create file"); /* If problem, send error msg */
  555.     RESUME;                /* and quit */
  556.     } else {                /* otherwise */
  557.     ack();                /* acknowledge the EOF packet */
  558.     BEGIN rfile;            /* and await another file */
  559.     }
  560. }
  561.  
  562. <rdata>Z {                /* End Of File (EOF) Packet */
  563. /*  wslots = 1;    */            /* Window size back to 1 */
  564. #ifndef COHERENT
  565. /*
  566.   Coherent compiler blows up on this switch() statement.
  567. */
  568.     x = reof(filnam, &iattr);        /* Handle the EOF packet */
  569.     switch (x) {            /* reof() sets the success flag */
  570.       case -3:                /* If problem, send error msg */
  571.     errpkt((CHAR *)"Can't print file"); /* Fatal */
  572.         RESUME;
  573.     break;
  574.       case -2:
  575.     errpkt((CHAR *)"Can't mail file"); /* Fatal */
  576.         RESUME;
  577.     break;
  578.       case 2:
  579.       case 3:
  580.     screen(SCR_EM,0,0l,"Can't delete temp file"); /* Not fatal */
  581.         RESUME;
  582.     break;
  583.       default:
  584.     if (x < 0) {            /* Fatal */
  585.         errpkt((CHAR *)"Can't close file");
  586.         RESUME;
  587.     } else {            /* Success */
  588.         ack();            /* Acknowledge the EOF packet */
  589.         BEGIN rfile;        /* and await another file */
  590.     }
  591.     }
  592. #else
  593.     if (reof(filnam, &iattr) < 0) {    /* Close and dispose of the file */
  594.     errpkt((CHAR *)"Error at end of file");
  595.     RESUME;
  596.     } else {                /* reof() sets success flag */
  597.     ack();
  598.     BEGIN rfile;
  599.     }
  600. #endif /* COHERENT */
  601. }
  602.  
  603. <ssinit>Y {                /* ACK for Send-Init */
  604.     spar(rdatap);            /* set parameters from it */
  605.     bctu = bctr;            /* switch to agreed-upon block check */
  606.     bctl = (bctu == 4) ? 2 : bctu;    /* Set block-check length */
  607.     what = W_SEND;            /* Remember we're sending */
  608.     x = sfile(xflg);            /* Send X or F header packet */
  609.     if (x) {                /* If the packet was sent OK */
  610.     resetc();            /* reset per-transaction counters */
  611.     rtimer();            /* reset timers */
  612.     BEGIN ssfile;            /* and switch to receive-file state */
  613.     } else {                /* otherwise send error msg & quit */
  614.     s = xflg ? "Can't execute command" : "Can't open file";
  615.     errpkt((CHAR *)s);
  616.     RESUME;
  617.     }
  618. }
  619.  
  620. /*
  621.  These states are necessary to handle the case where we get a server command
  622.  packet (R, G, or C) reply with an S packet, but the client retransmits the 
  623.  command packet.  The input() function doesn't catch this because the packet 
  624.  number is still zero.
  625. */
  626. <ssinit>R {                /* R packet was retransmitted. */
  627.     xsinit();                /* Resend packet 0 */
  628. }
  629.  
  630. <ssinit>G {                /* Same deal if G packet comes again */
  631.     xsinit();
  632. }
  633.  
  634. <ssinit>C {                /* Same deal if C packet comes again */
  635.     xsinit();
  636. }
  637.  
  638. <ssfile>Y {                /* ACK for F packet */
  639.     srvptr = srvcmd;            /* Point to string buffer */
  640.     decode(rdatap,putsrv,0);        /* Decode data field, if any */
  641.     putsrv('\0');            /* Terminate with null */
  642.     ffc = 0L;                /* Reset file byte counter */
  643.     if (*srvcmd) {            /* If remote name was recorded */
  644.     if (fdispla == XYFD_C) screen(SCR_AN,0,0L,(char *)srvcmd);
  645.     tlog(F110," stored as",(char *) srvcmd,0L); /* Transaction log. */
  646.     }
  647.     if (atcapu) {            /* If attributes are to be used */
  648.     if (sattr(xflg | stdinf) < 0) {    /* set and send them */
  649.         errpkt((CHAR *)"Can't send attributes"); /* if problem, say so */
  650.         RESUME;                 /* and quit */
  651.     } else BEGIN ssattr;        /* if ok, switch to attribute state */
  652.     } else {
  653.     if (window(wslotn) < 0) {
  654.         errpkt((CHAR *)"Can't open window");
  655.         RESUME;
  656.     }
  657.     if (sdata() < 0) {        /* No attributes, send data */
  658.         clsif();            /* If not ok, close input file, */
  659.         window(1);            /* put window size back to 1, */
  660.         seof((CHAR *)"");        /* send EOF packet, */
  661.         BEGIN sseof;        /* and switch to EOF state. */
  662.     } else BEGIN ssdata;        /* All ok, switch to send-data state */
  663.     }
  664. }
  665.  
  666. <ssattr>Y {                /* Got ACK to A packet */
  667.     ffc = 0L;                /* Reset file byte counter */
  668.     if (rsattr(rdatap) < 0) {        /* Was the file refused? */
  669.     discard = 1;            /* Set the discard flag */
  670.     clsif();            /* Close the file */
  671.     sxeof((CHAR *)"D");        /* send EOF with "discard" code */
  672.     BEGIN sseof;            /* switch to send-EOF state */
  673.     } else {
  674.     if (window(wslotn) < 0) {    /* Allocate negotiated window slots */
  675.         errpkt((CHAR *)"Can't open window");
  676.         RESUME;
  677.     }
  678.     if (sdata() < 0) {        /* File accepted, send data */
  679.         clsif();            /* If problem, close input file */
  680.         window(1);            /* Window size back to 1... */
  681.         seof((CHAR *)"");        /* send EOF packet */
  682.         BEGIN sseof;        /* and switch to send-EOF state. */
  683.     } else {            /* All ok, enter send-data state. */
  684.         BEGIN ssdata;
  685.     }
  686.     }
  687. }
  688.  
  689. <ssdata>Y {                /* Got ACK to Data packet */
  690.     canned(rdatap);            /* Check if file transfer cancelled */
  691.     if (sdata() < 0) {            /* Try to send next data */
  692.     clsif();            /* If no more data, close file */
  693.     window(1);            /* Window size back to 1... */
  694.     if (cxseen || czseen)        /* If interrupted */
  695.       seof((CHAR *)"D");        /* send special EOF packet */
  696.     else seof((CHAR *)"");        /* Otherwise regular EOF packet */
  697.     BEGIN sseof;            /* And enter send-eof state */
  698.     }
  699. }
  700.  
  701. <sseof>Y {                /* Got ACK to EOF */
  702.     success = (cxseen == 0 && czseen == 0); /* Set this for IF command */
  703.     cxseen = 0;                /* This goes back to zero. */
  704.     if (gnfile() > 0) {            /* Any more files to send? */
  705.     if (sfile(xflg))        /* Yes, try to send next file header */
  706.       BEGIN ssfile;            /* if ok, enter send-file state */
  707.     else {                /* otherwise */
  708.         errpkt((CHAR *)"Can't open file");    /* send error message */
  709.         RESUME;            /* and quit */
  710.     }
  711.     } else {                /* No next file */
  712.     tsecs = gtimer();        /* get statistics timers */
  713.     seot();                /* send EOT packet */
  714.     BEGIN sseot;            /* enter send-eot state */
  715.     }
  716. }
  717.  
  718. <sseot>Y {                /* Got ACK to EOT */
  719.     RESUME;                /* All done, just quit */
  720. }
  721.  
  722. E {                    /* Got Error packet, in any state */
  723.     ermsg((char *)rdatap);        /* Issue message. */
  724.     success = 0;            /* For IF SUCCESS/FAIL. */
  725.     debug(F101,"ckcpro.w sstate at E pkt","",sstate);
  726.     x = quiet; quiet = 1;        /* Close files silently, */
  727.     clsif(); clsof(1);             /* discarding any output file. */
  728.     tsecs = gtimer();            /* Get timers */
  729.     quiet = x;                /* restore quiet state */
  730. /*
  731.   If we are executing commands from a command file or macro, let the command
  732.   file or macro decide whether to exit, based on SET { TAKE, MACRO } ERROR.
  733. */
  734.     if (
  735. #ifndef NOSPL
  736.     cmdlvl == 0
  737. #else
  738.     tlevel < 0
  739. #endif /* NOSPL */
  740.     )
  741.       if (backgrd && !server)
  742.     fatal("Protocol error");
  743.     xitsta |= what;            /* Save this for doexit(). */
  744.     RESUME;
  745. }
  746.  
  747. q { success = 0; QUIT; }        /* Ctrl-C interrupt during packets. */
  748.  
  749. . {                    /* Anything not accounted for above */
  750.     errpkt((CHAR *)"Unexpected packet type"); /* Give error message */
  751.     xitsta |= what;            /* Save this for doexit(). */
  752.     RESUME;                /* and quit */
  753. }
  754. %%
  755.  
  756. /*  P R O T O  --  Protocol entry function  */
  757.  
  758. VOID
  759. proto() {
  760.  
  761.     int x;
  762.     long lx;
  763.  
  764. /* Set up the communication line for file transfer. */
  765.  
  766.     if (local && (speed < 0L) && (network == 0)) {
  767.     screen(SCR_EM,0,0l,"Sorry, you must 'set speed' first");
  768.     return;
  769.     }
  770.     x = -1;
  771.     if (ttopen(ttname,&x,mdmtyp,cdtimo) < 0) {
  772.     debug(F111,"failed: proto ttopen local",ttname,local);
  773.     screen(SCR_EM,0,0l,"Can't open line");
  774.     return;
  775.     }
  776.     if (x > -1) local = x;
  777.     debug(F111,"proto ttopen local",ttname,local);
  778.  
  779.     lx = (local && !network) ? speed : -1;
  780. #ifdef NETCONN
  781. #ifdef CK_SPEED
  782. /*
  783.   If we are a TELNET client, force quoting of IAC.
  784.   Note hardwired "1" rather than NP_TELNET symbol, so we don't have
  785.   to schlurp in ckcnet.h.
  786. */
  787.     if (network && ttnproto == 1) {
  788.     ctlp[255] = 1;
  789.     if (parity == 'e' || parity == 'm') ctlp[127] = 1;
  790.     }
  791. #endif /* CK_SPEED */
  792. #endif /* NETCONN */
  793.     if (ttpkt(lx,flow,parity) < 0) {    /* Put line in packet mode, */
  794.     screen(SCR_EM,0,0l,"Can't condition line");
  795.     return;
  796.     }
  797.     if (!local) connoi();        /* No console interrupts if remote */
  798.  
  799.     if (sstate == 'x') {        /* If entering server mode, */
  800.     server = 1;            /* set flag, */
  801.     debug(F101,"server backgrd","",backgrd);
  802.     debug(F101,"server quiet","",quiet);
  803.     if (!quiet && !backgrd) {
  804.             debug(F100,"SHOULD NOT SEE THIS IF IN BACKGROUND!","",0);
  805.         if (!local)    {        /* and issue appropriate message. */
  806.             conoll(srvtxt);
  807.         conoll("KERMIT READY TO SERVE...");
  808.         } else {
  809.             conol("Entering server mode on ");
  810.         conoll(ttname);
  811.         conoll("Type Ctrl-C to quit.");
  812.         if (srvdis) intmsg(-1L);
  813.         }
  814.     }
  815.     } else server = 0;
  816. #ifdef VMS
  817.     if (!quiet && !backgrd)    /* So message doesn't overwrite prompt */
  818.       conoll("");
  819.     if (local) conres();       /* So Ctrl-C will work */
  820. #endif /* VMS */
  821. /*
  822.   If in remote mode, not shushed, not in background, and at top command level,
  823.   issue a helpful message telling what to do...
  824. */
  825.     if (!local && !quiet && !backgrd &&
  826. #ifndef NOSPL
  827.     cmdlvl == 0
  828. #else
  829.     tlevel < 0
  830. #endif /* NOSPL */
  831.     ) {
  832.     if (sstate == 'v') {
  833.         conoll("Return to your local Kermit and give a SEND command.");
  834.         conoll("");
  835.         conoll("KERMIT READY TO RECEIVE...");
  836.     } else if (sstate == 's') {
  837.         conoll("Return to your local Kermit and give a RECEIVE command.");
  838.         conoll("");
  839.         conoll("KERMIT READY TO SEND...");
  840.     } else if ( sstate == 'g' || sstate == 'r' || sstate == 'c' ) {
  841.         conoll("Return to your local Kermit and give a SERVER command.");
  842.         conoll("");
  843.         conoll((sstate == 'r') ?
  844.            "KERMIT READY TO GET..." :
  845.            "KERMIT READY TO SEND SERVER COMMAND...");
  846.     }
  847.     }
  848.     sleep(1);
  849. /*
  850.  The 'wart()' function is generated by the wart program.  It gets a
  851.  character from the input() routine and then based on that character and
  852.  the current state, selects the appropriate action, according to the state
  853.  table above, which is transformed by the wart program into a big case
  854.  statement.  The function is active for one transaction.
  855. */
  856.     rtimer();                /* Reset elapsed-time timer */
  857.     wart();                /* Enter the state table switcher. */
  858.     
  859.     if (server) {            /* Back from packet protocol. */
  860.         if (!quiet && !backgrd) {    /* Give appropriate message */
  861.         conoll("");
  862.         conoll("C-Kermit server done");
  863.     }
  864.     }
  865. /*
  866.   Note: the following is necessary in case we have just done a remote-mode
  867.   file transfer, in which case the controlling terminal modes have been
  868.   changed by ttpkt().  In particular, special characters like Ctrl-C and
  869.   Ctrl-\ might have been turned off (see ttpkt).  So this call to ttres() is
  870.   essential.
  871. */
  872. #ifndef OS2
  873.     if (!local)
  874. #endif /* OS2 */
  875.       ttres();                /* Reset the communication device */
  876.     screen(SCR_TC,0,0l,"");        /* Transaction complete */
  877.     server = 0;                /* Not a server any more */
  878. }
  879.